fairnesscoop / permacoop

@CommandHandler(CreateNotificationCommand)

export class CreateNotificationCommandHandler {

  constructor(

    @Inject('INotificationRepository')

    private readonly notificationRepository: INotificationRepository,

    @Inject('IMattermostNotifier')

    private readonly mattermostNotifier: IMattermostNotifier,

    ) {}

  public async execute(command: CreateNotificationCommand): Promise<string> {

    const { message, type, leaveReaquest } = command;

    if (type === NotificationType.POST) {

      const { id } = await this.mattermostNotifier.createPost(MATTERMOST_CHANNEL_LEAVES_ID, message);

      const notification = await this.notificationRepository.save(

        new Notification(

          type,

          message,

          id,

          leaveReaquest

        )

      );

      return notification.getId();

    }

    throw new Error('Type not managed');